package com.gzp.broker;

import org.apache.activemq.broker.BrokerService;

/**
 * 内嵌的activemq服务器
 * 
 * @author Administrator
 *
 */
public class EmbedBroker {

	private static final String bindAddress = "tcp://localhost:61617";

	public static void main(String[] args) throws Exception {
		BrokerService brokerService = new BrokerService();
		brokerService.setUseJmx(true);
		brokerService.addConnector(bindAddress);
		brokerService.start();
	}
}
